const mysql = require("mysql");
const { mysqlConfig } = require("../conf/db.js");

// 创建连接对象
const con = mysql.createConnection(mysqlConfig);

// 开始连接
con.connect();

// 统一执行的sql语句
function exec(sql) {
  return new Promise((resolve, reject) => {
    console.log(sql);
    con.query(sql, (err, result) => {
      if (err) {
        reject(err);
        return;
      }
      resolve(result);
    })
  })
}

module.exports = {
  exec
}